package cn.zzm.replyTo;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Component;

/**
 * springboot自动装配JMS的写法
 * Request-Response模式
 */
@Component
public class ConsumerR {
    /**
     * 表示消费springboot.queue,消费成功后返回信息到replyTo.queue中
     * @param text
     * @return
     */
    @JmsListener(destination = "replyTestqueue")
    @SendTo("replyTo.queue")
    public String receiveQueue(String text) {
        System.out.println(this.getClass().getName()+" 收到的报文为:"+text);
        return "我已经收到消息："+text;
    }
}
